package demo.T泛型.service;

import demo.T泛型.AbstractDefaultServiceImpl;
import demo.T泛型.pojo.MRequest;
import demo.T泛型.util.PojoBase;

import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class IDataMigrationService4SFP {

    private AbstractDefaultServiceImpl<PojoBase> moveService;

    private ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(4, 4, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingDeque<>(10));

    public void execute(MRequest mRequest){

        threadPoolExecutor.submit(new IDataMigrationServiceThread4SFP(moveService,mRequest,2));
    }

}
